f883209257ec162a66b61778c9d01d74fbe938dd,tests/junit/org/jgroups/tests/ConcurrentStartFlushTest.java,ConcurrentStartFlushTest,testFlushStartedByOneButCompletedByOther,#,107
Before Change
Util.sleep(1000);
System.out.println("Stopping flush at C2");
c2.stopFlush();
Util.sleep(1000);
System.out.println("Stopping flush at C1");
After Change
public void testFlushStartedByOneButCompletedByOther() throws Exception {
c1 = createChannel();
r1=new Receiver("C1", c1);
c2 = createChannel();
r2=new Receiver("C2", c2);
c3 = createChannel();
r3=new Receiver("C3", c3);
c1.setReceiver(r1);
c2.setReceiver(r2);
c3.setReceiver(r3);
c1.connect("test");
c2.connect("test");
c3.connect("test");
Util.sleep(1000);
System.out.println("starting flush at C1");
boolean rc=c1.startFlush(TIMEOUT, false);
assertTrue(rc);
Util.sleep(500);
Util.sleep(1000);
System.out.println("Stopping flush at C2");
c2.stopFlush();
System.out.println("starting flush at C2");
rc=c2.startFlush(TIMEOUT, false);